package org.uiot.process

class SamplingJob implements StreamJobTraits, RmqInputTraits, JdbcOutputTraits {

    static constraints = {
        flinkInst()
        checkPointing()
        rmqInput()
        sourceQueue()
    }

    @Override
    void submit(String operator) {

    }
}
